import generate_delta

if __name__ == '__main__':
    conf_list, mode_list, source_tables = generate_delta.read_conf()
    rep = generate_delta.generate_replica_tables(source_tables)
    # globals()['a'] = '3'
    # print(a.replace('3','2'))
    all = generate_delta.table_distribute(source_tables, rep)
    p1 = all[0]
    partition_list_expect = generate_delta.generate_date_range(p1[0])
    print(generate_delta.capture_partitions(p1[0], partition_list_expect= partition_list_expect))
    # generate_delta.update_conf(conf_list, mode_list)
